/*
package org.xg.study.spring.al.controller;

import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
import org.xg.study.spring.al.pojo.MyMessage;

*/
/**
 * @author CMG
 * @version 1.0
 * @description
 * @cLassName TestConsumerListener
 * @date 2021/10/27 10:09
 **//*

@Slf4j
@Component
// topic需要和生产者的topic一致，consumerGroup属性是必须指定的，内容可以随意
@RocketMQMessageListener(topic = "test-topic", consumerGroup = "consumer-group")
public class TestConsumerListener implements RocketMQListener<MyMessage>  {
    */
/**
     * 监听到消息的时候就会调用该方法
     *//*

    @Override
    public void onMessage(MyMessage message) {
        log.info("从test-topic中监听到消息");
        log.info(JSON.toJSONString(message));
    }
}
*/
